package hamster.csustef.acquisition.constant;

public class AcquisitionConstant {

    /**
     * 爬取周期
     */
    // 起始等待周期
    public static final int FIRST_TERM = 1000 * 60 * 30;
    // 电表爬取周期
    public static final int ELECTRIC_FEE_TERM = 1000 * 60 * 30;
    // 寝室间爬取间隔
    public static final int ELECTRIC_FEE_GAP = 200;
    // 长沙天气爬取周期
    public static final int CS_WEATHER_TERM = 1000 * 60 * 2;
    /**
     * Kafka相关参数
     */

    public static final String KAFKA_SERVERS = "master:9092";
    // 电表原始数据主题
    public static final String ELECTRIC_FEE_TOPIC = "ods.ods_electric_fee";


    // 长沙天气原始数据主题
    public static final String CS_WEATHER_TOPIC = "ods.ods_changsha_weather";
    // 长沙天气状态主题
    public static final String CS_WEATHER_STATE_TOPIC = "ods.ods_changsha_weather_state";


    /**
     * 存储地址
     */
    // 临时文件存储地址
    public static final String TEMP_FILE_PATH = "hdfs://master:8020/tmp/project/csustef";
    // 电表数据临时文件地址
    public static final String ELECTRIC_FEE_TEMP_FILE_PATH = TEMP_FILE_PATH + "/electric_fee";
    // 长沙天气临时文件地址
    public static final String CS_WEATHER_TEMP_FILE_PATH = TEMP_FILE_PATH + "/changsha_weather";


}
